caced3749bdf640abf2a7f06056f6c29789385e4,cdap-watchdog/src/test/java/co/cask/cdap/metrics/store/cube/AbstractCubeTest.java,AbstractCubeTest,test,#,43

Before Change


    writeInc(cube, "metric1",  7,  3,  "1",  "1", null);
    writeInc(cube, "metric1",  8,  2, null,  "1", null);
    writeInc(cube, "metric1",  9,  1, null, null, null);
    writeInc(cube, "metric1", 10,  2,  "1",  "1",  "1",  "1");
    writeInc(cube, "metric1", 11,  3,  "1",  "1",  "1", null);
    writeInc(cube, "metric1", 12,  4,  "2",  "1",  "1",  "1");
    writeInc(cube, "metric1", 13,  5, null, null, null,  "1");

After Change


                                              ImmutableList.of("tag1"));

    int resolution = 1;
    Cube cube = getCube("myCube", new int[] {resolution}, ImmutableList.of(agg1, agg2));

    // write some data
    // NOTE: we mostly use different ts, as we are interested in checking incs not at persist, but rather at query time
    writeInc(cube, "metric1",  1,  1,  "1",  "1",  "1");
    writeInc(cube, "metric1",  1,  1,  "1",  "1",  "1");
    writeInc(cube, "metric1",  2,  2, null,  "1",  "1");
    writeInc(cube, "metric1",  3,  3,  "1",  "2",  "1");
    writeInc(cube, "metric1",  3,  5,  "1",  "2",  "3");
    writeInc(cube, "metric1",  3,  7,  "2",  "1",  "1");
    writeInc(cube, "metric1",  4,  4,  "1", null,  "2");
    writeInc(cube, "metric1",  5,  5, null, null,  "1");
    writeInc(cube, "metric1",  6,  6,  "1", null, null);
    writeInc(cube, "metric1",  7,  3,  "1",  "1", null);
    writeInc(cube, "metric1",  8,  2, null,  "1", null);
    writeInc(cube, "metric1",  9,  1, null, null, null);
    // writing in batch
    cube.add(ImmutableList.of(
      getFact("metric1", 10,  2,  "1",  "1",  "1",  "1"),
      getFact("metric1", 11,  3,  "1",  "1",  "1", null),
      getFact("metric1", 12,  4,  "2",  "1",  "1",  "1"),
      getFact("metric1", 13,  5, null, null, null,  "1")